package com.ydl.learning.flink.demo.mySource

import com.ydl.learning.flink.demo.Utils
import org.apache.flink.api.scala._

/**
 *
 *
 * @author ydl
 * @since 2020/12/9
 */
object Demo extends App with Utils {
  streamEnv.addSource(new StringSource).setParallelism(1).print()
  streamEnv.execute("my source")

}
